package com.shidaimanong.demo.chat;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

/**
 * 学编程，关注：十代码农
 * 抖音、快手、B站、西瓜视频、今日头条
 */
public class ChatServerDemo {
    public static void main(String[] args) throws IOException {
        int serverPort = 7788;//服务器端口
        // 1.在指定端口创建服务端DatagramSocket
        DatagramSocket datagramSocket = new DatagramSocket(serverPort);
        // 2.创建数据包，用于接收客户端数据
        byte[] data = new byte[1024];// 创建字节数组，指定接收的数据包的大小，默认1024就可以了
        DatagramPacket requestPacket = new DatagramPacket(data, data.length);
        // 3.接收客户端数据
        System.out.println("服务端已启动，等待客户端发送消息");
        while (true) {
            datagramSocket.receive(requestPacket);// 此方法在接收到数据之前会一直阻塞
            // 4.读取数据
            String info = new String(data, 0, requestPacket.getLength());
            System.out.println("客户端发言：" + info);
        }
    }
}
